package com.tanhua.sso.config;

import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;

import java.util.Map;

@Slf4j
@Component  //必须注入spring容器
@RocketMQMessageListener(                       //声明当前类为RocketMQ的消息监听器
        consumerGroup = "tanhua",               //group：在消费者这边指定，不是必须生产者使用同一组别
        topic = "tanhua-sso-login", 			//topic：和消费者发送的topic相同
        selectorExpression = "*") 			    //tag
public class LoginMQListner implements RocketMQListener<Map> {//泛型建议和接收的消息类型相同，也可以使用String类型参数接收，表示json格式字符串
    /**
     * 当监听到消息信息后执行该方法
     * @param userInfo
     */
    public void onMessage(Map userInfo) {
        log.info("登录监听器，接收到的MQ消息为：" + userInfo);
    }
}
